//package com.yl.test;
//
//import org.apache.flink.api.common.functions.RichMapFunction;
//import org.influxdb.dto.Point;
//
//import java.util.List;
//import java.util.concurrent.TimeUnit;
//
///**
// * @author wlf
// * @since 2022/8/1
// */
//public class StrMapFunc extends RichMapFunction<List<Object>, String> {
//
//    private String tbl;
//
//    public StrMapFunc(String tbl) {
//        this.tbl = tbl;
//    }
//
//    @Override
//    public String map(List<Object> objectList) throws Exception {
//        int i = 0;
//        Point.Builder pointBuilder = Point.measurement(tbl);
//        pointBuilder
//                .time(Long.parseLong(objectList.get(i++).toString()), TimeUnit.MILLISECONDS)
//                .tag("tid", objectList.get(i++).toString())
//                .addField("v1", Double.parseDouble(objectList.get(i++).toString()))
//                .addField("v2", Double.parseDouble(objectList.get(i++).toString()))
//                .addField("v3", Double.parseDouble(objectList.get(i).toString()));
//        return pointBuilder.build().lineProtocol();
//    }
//}
